#include <iostream>
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>

pthread_cond_t cond;   // 条件变量
pthread_mutex_t mutex; // 锁

int t = 100;

void *func(void *arg)
{
    while (true)
    {
        // 上锁
        pthread_mutex_lock(&mutex);

        // 添加条件变量 -等待+释放锁  唤醒+重新申请锁
        pthread_cond_wait(&cond, &mutex);

        if (t > 0)
        {
            printf("%s : t = %d\n", (char *)arg, t);    //这里需要使用\n保证内容刷新到内核级缓冲区
            t--;
        }
        else
        {
            pthread_mutex_unlock(&mutex);
            break;
        }

        // 释放锁
        pthread_mutex_unlock(&mutex);
    }

    return nullptr;
}

int main()
{
    // 1.初始化锁和条件变量
    pthread_mutex_init(&mutex, nullptr);
    pthread_cond_init(&cond, nullptr);

    // 2.创建线程
    pthread_t pt1, pt2;
    pthread_create(&pt1, nullptr, func, (void *)"线程-1");
    pthread_create(&pt2, nullptr, func, (void *)"线程-2");

    // 3.主线程进程唤醒
    sleep(3);
    while (true)
    {
        pthread_cond_broadcast(&cond); // 广播式唤醒线程
        //pthread_cond_signal(&cond);    // 选取其中一个
        //sleep(1);
    }

    // 4.主线程进程等待
    pthread_join(pt1, nullptr);
    pthread_join(pt2, nullptr);

    //5.销毁条件变量和锁
    pthread_cond_destroy(&cond);
    pthread_mutex_destroy(&mutex);

    return 0;
}